package com.yss.kettle.service;

import com.yss.kettle.domain.JobRelation;
import com.baomidou.mybatisplus.extension.service.IService;
import com.yss.kettle.domain.JobTask;

import java.util.List;
import java.util.Map;

/**
 * 任务关联关系Service接口
 *
 * @author yss
 * @date 2023-05-04
 */
public interface IJobRelationService extends IService<JobRelation> {

    /**
     * 查询任务关联关系列表
     *
     * @param jobRelation 任务关联关系
     * @return 任务关联关系集合
     */
    public List<JobRelation> selectJobRelationList(JobRelation jobRelation);


    /**
     * 获取所有执行任务中的 新的依赖关系
     *
     * @param ids 任务id
     * @return
     */
    public Map<String, List<String>> queryRelation(List<String> ids);

    /**
     * 保存任务的对应关系
     *
     * @throws Exception
     */
    public void insertJobRelation(JobTask jobTask);
}
